org.springframework.http.codec.json

Class Jackson2Tokenizer

java.lang.Object

org.springframework.http.codec.json.Jackson2Tokenizer

All Implemented Interfaces:

java.util.function.Function<DataBuffer,<any>>

class Jackson2Tokenizer
extends java.lang.Object
implements java.util.function.Function<DataBuffer,<any>>

Function to transform a JSON stream of arbitrary size, byte array chunks into a Flux<TokenBuffer> where each token buffer is a well-formed JSON object.

Since:

5.0

Author:

Arjen Poutsma

Field Summary

Fields

Modifier and Type	Field and Description
private int	arrayDepth
private ByteArrayFeeder	inputFeeder
private int	objectDepth
private JsonParser	parser
private TokenBuffer	tokenBuffer
private boolean	tokenizeArrayElements

Constructor Summary

Constructors

Constructor and Description
Jackson2Tokenizer(JsonParser parser, boolean tokenizeArrayElements) Create a new instance of the Jackson2Tokenizer.

Method Summary

Modifier and Type	Method and Description
<any>	apply(DataBuffer dataBuffer)
void	endOfInput()
private boolean	isTopLevelArrayToken(JsonToken token)
private void	processTokenArray(JsonToken token, java.util.List<TokenBuffer> result)
private void	processTokenNormal(JsonToken token, java.util.List<TokenBuffer> result)
private void	updateDepth(JsonToken token)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Field Detail

parser

private final JsonParser parser

tokenizeArrayElements

private final boolean tokenizeArrayElements

tokenBuffer

private TokenBuffer tokenBuffer

objectDepth

private int objectDepth

arrayDepth

private int arrayDepth

inputFeeder

private final ByteArrayFeeder inputFeeder

Constructor Detail

Jackson2Tokenizer

public Jackson2Tokenizer(JsonParser parser,
                         boolean tokenizeArrayElements)

Create a new instance of the Jackson2Tokenizer.

Parameters:

parser - the non-blocking parser, obtained via com.fasterxml.jackson.core.JsonFactory#createNonBlockingByteArrayParser

tokenizeArrayElements - if true and the "top level" JSON object is an array, each element is returned individually, immediately after it is received.

Method Detail

apply

public <any> apply(DataBuffer dataBuffer)

Specified by:

apply in interface java.util.function.Function<DataBuffer,<any>>

updateDepth

private void updateDepth(JsonToken token)

processTokenNormal

private void processTokenNormal(JsonToken token,
                                java.util.List<TokenBuffer> result)
                         throws java.io.IOException

Throws:

java.io.IOException

processTokenArray

private void processTokenArray(JsonToken token,
                               java.util.List<TokenBuffer> result)
                        throws java.io.IOException

Throws:

java.io.IOException

isTopLevelArrayToken

private boolean isTopLevelArrayToken(JsonToken token)

endOfInput

public void endOfInput()